package com.qfjy.controller.example1;

import com.qfjy.mq.QueueTask;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

/**
 * @ClassName AccountController
 * @Description TODO  帐户操作 业务逻辑
 * @Author guoweixin
 * @Date 2022/4/1
 * @Version 1.0
 */
@Controller
@Slf4j
@RequestMapping("account")
public class AccountController {

    /**
     * JDBCTemplate
     * RestTemplate
     * RedisTemplate
     *  TODO 消息队列模版
     */
    @Autowired
    private AmqpTemplate amqpTemplate;

    /**
     * TODO 发工资方法 根据卡号
     * @param cardId
     */
    @GetMapping("sendWage")
    @ResponseBody
    public String sendWage(@RequestParam("cardId")String cardId){

        log.info("后台逻辑完成了发放工资--》帐号是："+cardId);

        //发送邮件任务队列 发送到rabbitmq
        /**
         * param1 队列名称
         * param2 数据的传输对象（二进制）
         */
        amqpTemplate.convertAndSend(QueueTask.QUEUE_NAME_EMAIL,cardId);

        return "工资发放成功--》"+cardId;
    }


}
